package com.winit.core.mq.queue;

import com.winit.core.mq.listener.QueueListener;
import com.winit.core.mq.message.Message;

/**
 * Created by xiangyu.liang on 2016/8/15.
 */
public interface MessageQueue {
    public boolean enqueue(Message message);
    public void addListener(QueueListener listener);
    public void removeListener(Object object);
    public boolean hasListener();
    public void destroy();
}
